-
Notifications
You must be signed in to change notification settings - Fork 26
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add resource_profile support #52
Conversation
294254d
to
d646e94
Compare
test/test_spark.py
Outdated
with parallel_backend('spark', | ||
num_cpus_per_spark_task=self.num_cpus_per_spark_task, | ||
num_gpus_per_spark_task=self.num_gpus_per_spark_task) as (ba, _): | ||
Parallel(n_jobs=5)(delayed(get_spark_context)(i) for i in range(10)) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let's test with num_gpus_per_spark_task different with default value, like:
with parallel_backend('spark', | |
num_cpus_per_spark_task=self.num_cpus_per_spark_task, | |
num_gpus_per_spark_task=self.num_gpus_per_spark_task) as (ba, _): | |
Parallel(n_jobs=5)(delayed(get_spark_context)(i) for i in range(10)) | |
with parallel_backend('spark', | |
num_cpus_per_spark_task=2, | |
num_gpus_per_spark_task=2) as (ba, _): | |
Parallel(n_jobs=5)(delayed(get_spark_context)(i) for i in range(10)) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM except a few minor comments!
74cf97c
to
bceb7b5
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Add extra param
resource_profile
and setup the resource profile if resource profile is supported.